package cn.vc.basicmodule.rabbitmqconfig;

import org.springframework.amqp.core.*;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class VideoRabbitMqConfig {
    @Bean
    public DirectExchange videoDirectExchange() {
        return new DirectExchange("video.direct", true, false);
    }
    /**
     * <h2>视频审核申请</h2>
     * @return
     */
    @Bean
    public Queue videoApplyQueue() {
        return QueueBuilder.durable("video.queue.save").build();
    }
    @Bean
    public Binding videoApplyBinding() {
        return BindingBuilder.bind(videoApplyQueue()).to(videoDirectExchange()).with("save");
    }
    /**
     * <h2>视频审核通过</h2>
     */
    @Bean
    public Queue videoPublishQueue() {
        return QueueBuilder.durable("video.queue.publish").build();
    }
    @Bean
    public Binding videoPublishBinding() {
        return BindingBuilder.bind(videoPublishQueue()).to(videoDirectExchange()).with("publish");
    }
}
